package com.jvm123

import io.reactivex.rxjava3.core.Observable
import io.reactivex.rxjava3.core.Observer

/**
 * @author yawn
 */
// 创建Observable框架 （使用MyPublisher）
Observable<Collection<String>> observable = Observable.create(new DataPublisher())
// 初始化一个 Observer （观察者）
Observer<Collection<String>> observer = new ExecutorObserver()
// 订阅到这个observer
observable.subscribe(observer)


/*
单线程：
1614302295101
1614302339776
44675

线程池：

3  3028
4  2747
5  2585
6  2200
7  2547
8  2432
9  2257
10 2460
11 3261
12 3091



 */

